<?php 
/**
 *  model.class.php 数据模型基类
 *  author william
 */

load_class('db_factory', '', 0);
class model {
	
	//数据库配置
	protected $db_config = [];

	//调用数据库的配置项
	protected  $db_setting = 'default';
	//数据表名
	protected  $table_name = '';
	//表前缀
	public  $db_tablepre = '';
	public  $_pk ='';
	public function __construct()
    {
        if(!empty($this->db_config)){
            $this->table_name = $this->getFullTableName($this->db_config[$this->db_setting]['tablepre'],$this->table_name);
            $this->db_tablepre = $this->db_config[$this->db_setting]['tablepre'];
        }
        return $this;
	}

	public  function useConnect($connect)
    {
        $db_config = load_config('database');
        $this->db_setting  = $connect;
        $this->table_name  = $this->getFullTableName($db_config[$connect]['tablepre'],$this->table_name);
        $this->db_tablepre = $db_config[$connect]['tablepre'];
    }

    /**
     * 组装完整的表名
     * @param $prefix 表前缀
     * @param $tblName 名称
     * @return string
     */
    public function getFullTableName($prefix,$tblName)
    {
        if(stripos($tblName,$prefix) !== false){
            return $tblName;
        }
	    return $prefix.$tblName;
    }

    /**
     * 获取数据错误信息
     * @return mixed
     */
    public function getError()
    {
        return $this->getDb()->getError();
    }

    /**
     * 获取数据错误号
     * @return mixed
     */
    public function getErrorNo()
    {
        return $this->getDb()->getErrorNo();
    }

    /**
     * 获取最后运行的sql
     * @return mixed
     */
	public function getLastSql()
    {
        return $this->getDb()->lastSql;
    }

    /**
     * 根据主键id获取一行记录
     * @param $id    主键数值
     * @param $field 字段名称,逗号隔开
     * @param  $limit 获取的数目，默认是1
     * @return array|bool
     */
	public function findOne($id,$field='*',$limit = 1)
    {
        if(!$this->_pk){
            return false;
        }
        return self::get_one([$this->_pk=>$id],$field,$limit);
    }
		
	/**
	 * 执行sql查询
	 * @param $where 		查询条件[例`name`='$name']
	 * @param $field 		需要查询的字段值[例`name`,`gender`,`birthday`]
	 * @param $limit 		返回结果范围[例：10或10,10 默认为空]
	 * @param $order 		排序方式	[默认按数据库默认方式排序]
	 * @param $group 		分组方式	[默认为空]
	 * @param $indexBy          返回数组按键名排序
	 * @return array		查询结果集数组
	 */
	final public function select($where = '', $field = '*', $limit = '', $order = '', $group = '', $indexBy='') {
		if (is_array($where)) $where = $this->sqls($where);
		return $this->getDb()->select($field, $this->table_name, $where, $limit, $order, $group, $indexBy);
	}

	/**
	 * 查询多条数据并分页
	 * @param $where
	 * @param $order
	 * @param $page
	 * @param $pagesize
	 * @return unknown_type
	 */
	final public function listinfo($where = '', $order = '', $page = 1, $pagesize = 20, $key='', $setpages = 10,$urlrule = '',$array = array(), $data = '*') {
		$where = to_sqls($where);
		$this->number = $this->count($where);
		$page = max(intval($page), 1);
		$offset = $pagesize*($page-1);
		$this->pages = pages($this->number, $page, $pagesize, $urlrule, $array, $setpages);
		$array = array();
		if ($this->number > 0) {
			return $this->select($where, $data, "$offset, $pagesize", $order, '', $key);
		} else {
			return array();
		}
	}

	/**
	 * 获取单条记录查询
	 * @param $where 		查询条件
	 * @param $field 		需要查询的字段值[例`name`,`gender`,`birthday`]
	 * @param $order 		排序方式	[默认按数据库默认方式排序]
	 * @param $group 		分组方式	[默认为空]
	 * @return array/null	数据查询结果集,如果不存在，则返回空
	 */
	final public function get_one($where = '', $field = '*', $order = '', $group = '') {
		if (is_array($where)) $where = $this->sqls($where);
		return $this->getDb()->get_one($field, $this->table_name, $where, $order, $group);
	}
	
	/**
	 * 直接执行sql查询
	 * @param $sql							查询sql语句
	 * @return	boolean/query resource		如果为查询语句，返回资源句柄，否则返回true/false
	 */
	final public function query($sql) {

		return $this->getDb()->query($sql);
	}
	
	/**
	 * 执行添加记录操作
	 * @param $data 		要增加的数据，参数为数组。数组key为字段值，数组值为数据取值
	 * @param $return_insert_id 是否返回新建ID号
	 * @param $replace 是否采用 replace into的方式添加数据
	 * @return boolean
	 */
	final public function insert($data, $return_insert_id = false, $replace = false) {
		return $this->getDb()->insert($data, $this->table_name, $return_insert_id, $replace);
	}
	
	/**
	 * 获取最后一次添加记录的主键号
	 * @return int 
	 */
	final public function insert_id() {
		return $this->getDb()->insert_id();
	}
	
	/**
	 * 执行更新记录操作
	 * @param $data 		要更新的数据内容，参数可以为数组也可以为字符串，建议数组。
	 * 						为数组时数组key为字段值，数组值为数据取值
	 * 						为字符串时[例：`name`='phpcms',`hits`=`hits`+1]。
	 *						为数组时[例: array('name'=>'phpcms','password'=>'123456')]
	 *						数组的另一种使用array('name'=>'+=1', 'base'=>'-=1');程序会自动解析为`name` = `name` + 1, `base` = `base` - 1
	 * @param $where 		更新数据时的条件,可为数组或字符串
	 * @return boolean
	 */
	final public function update($data, $where = '') {
		if (is_array($where)) $where = $this->sqls($where);
		return $this->getDb()->update($data, $this->table_name, $where);
	}
	
	/**
	 * 执行删除记录操作
	 * @param $where 		删除数据条件,不充许为空。
	 * @return boolean
	 */
	final public function delete($where) {
		if (is_array($where)) $where = $this->sqls($where);
		return $this->getDb()->delete($this->table_name, $where);
	}
	
	/**
	 * 计算记录数
	 * @param string/array $where 查询条件
	 */
	final public function count($where = '') {
		$r = $this->get_one($where, "COUNT(*) AS num");
		return $r['num'];
	}
	
	/**
	 * 将数组转换为SQL语句
	 * @param array $where 要生成的数组
	 * @param string $font 连接串。
	 */
	final public function sqls($where, $joinStr = ' AND ') {
		if (is_array($where)) {
            $sql = '';
//		    if( isset($where[0]) && in_array($where[0] ,[ 'in','not in']) && !empty($where[2])){
//		        $condition = $this->createIn($where[0],$where[1],$where[2]);
//                $sql .= $sql ? " $font {$condition} " : " {$condition}";
//            }else{
                foreach ($where as $key=>&$val) {
                    if( is_numeric($key) && is_string($val)){
                        $sql .= $sql ? " $joinStr {$val} " : " {$val}";
                    }else{
                        if(is_array($val) && !empty($val)){
                            $keys = array_keys($val);
                            $field =  array_shift($keys);
                            $values = array_values($val);
                            $value =  array_shift($values);
                        }else{
                            $field = $key;
                            $value = $val;
                        }
                        $sql .= $sql ? " $joinStr `$field` = '$value' " : " `$field` = '$value'";
                    }
                }
//            }
			return $sql;
		} else {
			return $where;
		}
	}
	
	/**
	 * 获取最后数据库操作影响到的条数
	 * @return int
	 */
	final public function affected_rows() {
		return $this->getDb()->affected_rows();
	}
	
	/**
	 * 获取数据表主键
	 * @return array
	 */
	final public function get_primary() {
		return $this->getDb()->get_primary($this->table_name);
	}
	
	/**
	 * 获取表字段
	 * @param string $table_name    表名
	 * @return array
	 */
	final public function get_fields($table_name = '') {
		if (empty($table_name)) {
			$table_name = $this->table_name;
		} else {
			$table_name = $this->db_tablepre.$table_name;
		}
		return $this->getDb()->get_fields($table_name);
	}
	
	/**
	 * 检查表是否存在
	 * @param $table 表名
	 * @return boolean
	 */
	final public function table_exists($table){
		return $this->getDb()->table_exists($this->db_tablepre.$table);
	}
	
	/**
	 * 检查字段是否存在
	 * @param $field 字段名
	 * @return boolean
	 */
	public function field_exists($field) {
		$fields = $this->getDb()->get_fields($this->table_name);
		return array_key_exists($field, $fields);
	}
	
	final public function list_tables() {
		return $this->getDb()->list_tables();
	}
	/**
	 * 返回数据结果集
	 * @param $query （mysql_query返回值）
	 * @return array
	 */
	final public function fetch_array() {
		$data = array();
		while($r = $this->getDb()->fetch_next()) {
			$data[] = $r;		
		}
		return $data;
	}
	
	/**
	 * 返回数据库版本号
	 */
	final public function version() {
		return $this->getDb()->version();
	}
	//开启一个事务
    final public function begin() {
        return $this->getDb()->query("START");
    }
    //提交一个事务
    final public function commit() {
        return $this->getDb()->query("COMMIT");
    }
    //事务回滚
    final public function rollback() {
        return $this->getDb()->query("ROLLBACK");
    }
    
    protected function getDb()
    {
        return \db_factory::get_instance($this->db_config)->get_database($this->db_setting);
    }
    /**
     * 当调用的方法不存在的时候会触发__call
     * @param $method
     * @param array $arguments
     */
    public function __call($method, $arguments=[])
    {
        ajaxReturn(['msg'=>'method '.$method .' not exist!','code'=>-196 ]);
    }

    /**
     * 组装in/not in查询
     * @param string $inType  IN或者NOT IN
     * @param $field
     * @param $value
     * @return string
     */
    public function createIn($inType='IN',$field,$value)
    {
        $str = '';
        if(empty($value) && !is_numeric($value)){
            return $str;
        }
        $field ='`'.$field.'`';
        if(is_array($value) ){
            foreach($value AS &$v){
                $arr[] =  "'".daddslashes($v)."'";
            }
            $str .= $field.strtoupper($inType).'('.implode(',',$arr).')';
        }else{
            $str .= $field."='".daddslashes($value)."'";
        }
        return $str;
    }
}